package com.lq.rocketmq.config;

/**
 * @program: myrocketmq
 * @description: 常量配置
 * @author: LQ
 * @create: 2021-05-08 09:44
 */

public class MyConstant {
//    public static String NAMESRV_ADDR = "192.168.233.250:9876;192.168.233.251:9876;192.168.32.130:9876;192.168.32.131:9876";
//    public static String NAMESRV_ADDR = "192.168.233.250:9876;192.168.233.251:9876";
    public static String NAMESRV_ADDR = "192.168.32.130:9876;192.168.32.131:9876";
    public static Integer MSG_COUNT = 10;
    public static String TOPIC = "base";
    public static String TOPIC_DELAY = "base_delay";
    public static String TOPIC_BATCH = "base_batch";
    public static String TOPIC_TAG_FILTER = "topic_tag_filter";
    public static String TOPIC_SQL_FILTER = "topic_sql_filter";
    public static String TOPIC_SQL_TRANSACTION = "topic_sql_transaction";
    public static String TAG1 = "tag1";
    public static String TAG2 = "tag2";
    public static String TAG3 = "tag3";
    public static String MSG_GROUP = "group";
    public static String MSG_GROUP_TRANSACTION = "msg_group_transaction";

}
